97201f1dbe08babce56ba6a1e2315530be49f545,src/main/java/reactor/core/publisher/FluxZip.java,ZipInner,onNext,#T#,920

Before Change


		@Override
		public void onNext(T t) {
			if (sourceMode != ASYNC) {
				queue.offer(t);
			}
			parent.drain();
		}

After Change


		@Override
		public void onNext(T t) {
			if (sourceMode != ASYNC) {
				if (!queue.offer(t)) {
					onError(Operators.onOperatorError(s, Exceptions.failWithOverflow("Queue is full?!"), t));
					return;
				}
			}
			parent.drain();
		}